package com.lds.memory.kafka.producer;

import java.util.Collection;

public interface IProducer<T> {
    void send(T data);

    void send(T data, String partitionKey);

    void batchSend(Collection<T> dataList);

    void batchSend(Collection<T> dataList, String partitionKey);

}
